package org.llc.flink.logs

import java.util

import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.llc.flink.logs.source.KafkaSink

object KafkaSinkClient {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    // 添加处理时间的类型
    env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

    val list = List()
//
//    //统计每个单词的数量
//    env.fromCollection(List(1,2,3))
//      .addSink(new KafkaSink().flinkKafkaProducer())
//      .setParallelism(4);
//    env.execute("sink demo : kafka str");

  }
}
